//package com.zhangdi.mgsync.core.rest.admin;
//
//import com.fasterxml.jackson.core.JsonProcessingException;
//import com.zhangdi.mgsync.core.rabbit.AdminTemplate;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.web.bind.annotation.GetMapping;
//import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.RestController;
//
//import java.util.ArrayList;
//import java.util.Date;
//
///**
// * @author zhangdi
// * @version 1.0
// * @date 2022.2.7 16:55
// */
//@RestController
//@RequestMapping("/mgsync/test")
//public class TestController {
//    @Autowired
//    AdminTemplate adminTemplate;
//
//    @GetMapping("/send")
//    public String sendTestDatas(String key) throws JsonProcessingException {
//        try {
//            adminTemplate.create("mgsync", key);
//        } catch (Exception e) {
//            return "创建失败交换器与队列失败";
//        }
//
//        List<DataInfo> datas = new ArrayList<>();
//        for (int i = 0; i < 1; i++) {
//            for (int j = 0; j < 500; j++) {
//                DataInfo data = new DataInfo();
//                data.setColl(key);
//                data.setId("假id_"+i+"_"+j);
//                data.setOp("insert");
//                data.setDt(new Date().getTime());
//                datas.add(data);
//            }
//            adminTemplate.send(key, datas);
//
//            datas = new ArrayList<>();
//        }
//
//        return "发送了很多消息到"+key;
//    }
//}
